//package com.sc.nft.consume;
//
//import com.sc.nft.entity.UserSynthesisRecord;
//import com.sc.nft.enums.MessageTopic;
//import com.sc.nft.service.IncomeServer;
//import lombok.extern.slf4j.Slf4j;
//import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
//import org.apache.rocketmq.spring.core.RocketMQListener;
//import org.springframework.stereotype.Component;
//
//import javax.annotation.Resource;
//
//@RocketMQMessageListener(topic = MessageTopic.USER_SYNTHESIS_RECORD_INCOME_INIT + "${spring.profiles.active}", consumerGroup = MessageTopic.USER_SYNTHESIS_RECORD_INCOME_INIT + "${spring.profiles.active}")
//@Component
//@Slf4j
//public class UserSynthesisRecordIncomeInitConsumer implements RocketMQListener<UserSynthesisRecord> {
//
//    @Resource
//    private IncomeServer incomeServer;
//
//    @Override
//    public void onMessage(UserSynthesisRecord message) {
//        incomeServer.userSynthesisRecordIncomeInit(message);
//    }
//
//}
